package com.reactor.mono;

import java.util.Optional;

import reactor.core.publisher.Mono;

public class Demo {

	/**Mono ,是指最多只能触发(emit) (事件)一次。它对应于 RxJava 库的 Single 和 Maybe 类型或者是java的Optional。因此一个异步任务，如果只是想要在完成时给出完成信号，就可以使用 Mono<Void>。
	 * 调用 Flux<T>的single()将返回一个 Mono<T>，而连接两个 monos一起使用 concatWith 将产生一个 Flux。
	 * @param args
	 */
	public static void main(String[] args) {
		Mono.fromSupplier(() -> "Hello").subscribe(System.out::println);
		Mono.justOrEmpty(Optional.of("Hello")).subscribe(System.out::println);
		Mono.create(sink -> sink.success("Hello")).subscribe(System.out::println);
	}

}
